/**
 * @author 陈泰来
 * @version V1.0
 * @Project echo-java-base
 * @Title 阻塞队列测试
 * @Description *
 * @Package concurrent.blockingQueue
 * @date 2021/3/19 1:57 下午
 * @Copyright:学如逆水行舟，不进则退 .
 */
package concurrent.blockingQueue.bqtest;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;

public class BQTest {

    public static final int BLOCKING_QUEUE_SIZE = 100;

    public static void main(String[] args) {
        BlockingQueue<String> bq = new ArrayBlockingQueue<>(BLOCKING_QUEUE_SIZE);
        Producer producer = new Producer(bq);
        Consumer consumer = new Consumer(bq);

        producer.start();
        consumer.start();

    }
}
